package com.zdxlz.fcmp.common.mqtt.handler;

import java.util.concurrent.CompletableFuture;

/**
 * @author: aman
 * @date 2025/2/11 9:01
 * @description mqtt 消息处理接口
 */
@FunctionalInterface
public interface MqttMessageHandler {
    CompletableFuture<Void> handleMessage(String topic, byte[] payload);
}
